03ade425dd5a65d3a713d5e7d85aa7605956fbd2,giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java,BspServiceWorker,storeCheckpointVertices,#,1502

Before Change


        GiraphConstants.NUM_CHECKPOINT_IO_THREADS.get(getConfiguration()),
        numPartitions);

    final Queue<Integer> partitionIdQueue =
        (numPartitions == 0) ? new LinkedList<Integer>() :
            new ArrayBlockingQueue<Integer>(numPartitions);
    Iterables.addAll(partitionIdQueue, getPartitionStore().getPartitionIds());

    final CompressionCodec codec =
        new CompressionCodecFactory(getConfiguration())

After Change


        GiraphConstants.NUM_CHECKPOINT_IO_THREADS.get(getConfiguration()),
        numPartitions);

    getPartitionStore().startIteration();

    final CompressionCodec codec =
        new CompressionCodecFactory(getConfiguration())